package org.example.service;

/**
 * @author jingjing.zhang
 */
public interface KafkaProcessHandler {
    /**
     * @param message
     */
    default void handler(String message) {
        throw new IllegalStateException("handler must be to implement");
    }
}
